//package com.yl.test;
//
//import cn.hutool.core.collection.ListUtil;
//import cn.hutool.core.date.DateTime;
//import cn.hutool.core.date.DateUnit;
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.NumberUtil;
//import com.yl.core.constant.Const;
//import com.yl.core.util.VoiceUtil;
//import com.yl.hawkeye.modules.settings.model.vo.PrimaryWarn;
//import com.hawkeye.entity.EmailVO;
//import com.hawkeye.util.SMSUtil;
//import lombok.extern.slf4j.Slf4j;
//import org.influxdb.InfluxDB;
//import org.influxdb.dto.Query;
//import org.influxdb.dto.QueryResult;
//import org.junit.Test;
//
//import java.io.File;
//import java.util.*;
//
//@Slf4j
//public class T1 {
//
//    @Test
//    public void test() {
//
//    }
//
//    @Test
//    public void test7() {
//        boolean warnSend = DefaultConfig.getWarnSend(Const.WARN_SEND_DING);
//        System.out.println(warnSend);
//    }
//
//    @Test
//    public void test6() {
//        String project = "yc";
//        String email = "waisaa@qq.com";
//        String file = "logs/processor.log";
//        ArrayList<File> files = ListUtil.toList(new File(file));
//        EmailVO emailVO = EmailVO.builder()
//                .email(email)
//                .title("天全车站项目")
//                .content("报表统计")
//                .build();
//        SMSUtil.sendMail(project, emailVO, files);
//    }
//
//    @Test
//    public void test5() {
//        String phone = "16601376898";
//        String[] params = {"天全车站1#滑坡体", "BC01", "水平位移", "一级", "北斗", "20毫米", "999999毫米"};
//        VoiceUtil.call(phone, params);
//    }
//
//    @Test
//    public void test4() {
//        PrimaryWarn warn1 = PrimaryWarn.builder().level(1).build();
//        PrimaryWarn warn2 = PrimaryWarn.builder().level(2).build();
//        PrimaryWarn warn3 = PrimaryWarn.builder().level(3).build();
//        Map<Integer, Integer> map = new HashMap<>();
//        map.put(1, 1);
//        map.put(2, 2);
//        map.put(3, 3);
//        Integer remove = map.remove(1);
//        System.out.println(remove);
//        System.out.println(map);
//    }
//
//    @Test
//    public void test3() {
//        System.out.println(DefaultConfig.getJobName());
////        SMSUtil.sendMsg("yc", "13911694327", "给我发条信息呗 我存一下[捂脸哭]设个不一样的铃声");
////        SMSUtil.sendMsg("cr11g_landslip", "16601376898", "给我发条信息呗 我存一下[捂脸哭]设个不一样的铃声");
//    }
//
//    @Test
//    public void test1() {
//        String thisTime = "2021-07-01 00:00:00";
//        String lastTime = "2021-07-02 00:10:00";
//        System.out.println(getInterval(thisTime, lastTime));
//    }
//
//    /**
//     * 获取数据间隔为这次的数据时间与上次的数据时间差，单位转换成小时
//     *
//     * @param thisTime 这次的数据时间，毫秒级标准格式
//     * @param lastTime 上次的数据时间，毫秒级标准格式
//     */
//    private double getInterval(String thisTime, String lastTime) {
//        DateTime beginDate = DateUtil.parse(lastTime);
//        DateTime endDate = DateUtil.parse(thisTime);
//        long between = DateUtil.between(beginDate, endDate, DateUnit.MINUTE);
//        return (double) between / 60;
//    }
//
//    @Test
//    public void test2() {
//        String sql = "SELECT tid, v4, v6 FROM raw_jmdb where time >= '2021-07-01 00:00:00' and  " +
//                "time < '2021-08-01 00:00:00' GROUP BY tid ORDER BY time desc LIMIT 1 tz('Asia/Shanghai')";
//        List<QueryResult.Series> series = executeSql(sql);
//        for (QueryResult.Series s : series) {
//            List<Object> values = s.getValues().get(0);
//            String date = values.get(0).toString().split("T")[0];
//            int tid = Integer.parseInt(values.get(1).toString());
//            double flowStart = NumberUtil.round(Double.parseDouble(values.get(2).toString()), 3).doubleValue();
//            double heatStart = NumberUtil.round(Double.parseDouble(values.get(3).toString()), 3).doubleValue();
//            System.out.println(ListUtil.toList(tid, date, flowStart, heatStart));
//        }
//    }
//
//    private static List<QueryResult.Series> executeSql(String sql) {
//        InfluxDB influxDB = DefaultConfig.getInfluxW();
//        QueryResult query = influxDB.query(new Query(sql));
//        return query.getResults().get(0).getSeries();
//    }
//
//}
